package com.bw.bean;


import lombok.Data;

import java.io.Serializable;

@Data
public class TableProcess implements Serializable {
    //动态分流Sink常量   改成小写和脚本一致

    public static final String SINK_TYPE_HBASE="hbase";
    public static final String SINK_TYPE_KAFKA="kafka";
    public static final String SINK_TYPE_CK="clickhouse";
    //来源表
    String sourceTable;
    //操作类型
    String operateType;
    //输出类型
    String sinkType;
    //输出表
    String sinkTable;
    //输出字段
    String SinkColumns;
    //主键字段
    String sinkPk;
    //建表扩展
    String sinkExtend;


}
